
#ifndef __DB_PGSQL_H__
#define __DB_PGSQL_H__

#include "libpq-fe.h"

// 连接数据库.
int db_connect();

// 关闭数据库.
int db_close();

// 执行一次性 SQL 语句.
int db_exec(char *sql);

// 执行SELECT, 返回结果:rows行, cols列.
// 执行此函数时,注意SQL语句,不要一次取出太多数据.可以多取几次.
int db_get_set(char *sql, int *rows, int *cols);

// 得到一个数据.
int db_get_field(char *data, int len, int row, int col);

int db_clear_result();

#endif // __DB_PGSQL_H__
